package org.ilc.push;

/**
 * 数据存储 查询 等接口
 * @author xumin
 *
 */
public interface IDataProvider {

	/**
	 * 从缓存队列中提取数据
	 * @return
	 */
	public Message next();
	/**
	 * 向缓存消息队列中存入数据
	 * @param user
	 * @param content
	 */
	public void cache(String user, String content);

	/**
	 * 把消息存入持久数据库
	 * 消息分为发送和未发送
	 * @param msg
	 */
	public void store(Message msg);
	
	/**
	 * 根据用户把持久数据库的数据添加到缓存
	 * @param user
	 */
    public void cacheFromStore(String user);
}
